package com.alibaba.otter.node.etl.load.loader.mq.rabbit.strategy;

import lombok.extern.slf4j.Slf4j;

//@Slf4j
//public class NotifyUser implements RescueAction {
//
//    private NotifyStrategy strategy;
//
//    public NotifyUser(String user) {
//        strategy = new NotifyViaWechat(user);
//    }
//
//    public NotifyUser(NotifyStrategy strategy) {
//        this.strategy = strategy;
//    }
//
//    @Override
//    public int handle(MqConsumeException ex) {
//        try {
//            strategy.notifyUser(ex);
//        } catch (Exception e) {
//            log.error("Failed to NotifyUser.", e);
//        }
//        return 1;
//    }
//}
